package com.example.administrator.testproject.rxjava;

import rx.Observable;
import rx.Subscriber;

/**
 * Created by shengfh on 2018/2/8.
 */

public class ObJs extends Observable {
    OnSubscribe subscriber;
    /**
     * Creates an Observable with a Function to execute when it is subscribed to.
     * <p>
     * <em>Note:</em> Use {@link #unsafeCreate(OnSubscribe)} to create an Observable, instead of this constructor,
     * unless you specifically have a need for inheritance.
     *
     * @param f {@link OnSubscribe} to be executed when {@link #subscribe(Subscriber)} is called
     */
    protected ObJs(OnSubscribe f) {
        super(f);
    }

    public void next(int count){
    }

}
